# !/usr/bin/env python
# -*- coding: utf-8 -*-
"""
 -------------------------------------------------
    File Name:     task.py
    Description:   
 -------------------------------------------------
 """
import time

import celery

# 1. 创建一个celery实例

# 2. 往应用中添加任务（注册任务）

# 3. 运行celery服务（cmd终端运行）
# cd celery_demo
# celery -A task worker -l info -P threads

# 定义消息中间件的地址
broker_url = 'redis://127.0.0.1:6379/1'

# 定义结果存储的地址
backend_url = 'redis://127.0.0.1:6379/2'
# 1. 创建一个celery实例
app = celery.Celery(main='celery_demo', broker=broker_url, backend=backend_url)


# 2. 往应用中添加任务（注册任务）
@app.task
def send_msg(name):
    print("给{}发送消息".format(name))
    time.sleep(2)
    print("发送消息完成")
    return True


@app.task
def send_email(name):
    print("给{}发送邮箱".format(name))
    time.sleep(2)
    print("发送邮箱完成")
    return True
